//package com.ly.system.consumer;
//
//import com.alibaba.fastjson.TypeReference;
//import com.ass.rocketmq.constant.MQTopic;
//import com.ass.rocketmq.consumer.AbstractConcurrencyPushConsumer;
//import com.domain.MQError;
//import com.ly.system.service.MQErrorService;
//import lombok.Getter;
//import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component;
//
//@Component
//@RequiredArgsConstructor
//@Slf4j
//public class MQErrorConsumer extends AbstractConcurrencyPushConsumer<MQError> {
//
//    @Getter
//    private final TypeReference<MQError> model = new TypeReference<MQError>(){};
//
//    @Getter
//    private final MQTopic mqTopic = MQTopic.ERROR;
//
//    private final MQErrorService mqErrorService;
//
//    @Override
//    protected void handler(MQError model, String keys) {
//        log.info("消息：{}",model);
//        mqErrorService.insert(model);
//    }
//}
